package com.lmf.rabbitmq.five;

import com.lmf.rabbitmq.utils.RabbitMqUtils;
import com.rabbitmq.client.Channel;

import java.io.IOException;
import java.util.Scanner;
import java.util.concurrent.TimeoutException;

/**
 * 演示Fanout型交换机 (生产者)：Fanout 这种类型非常简单。正如从名称中猜到的那样，它是将接收到的所有消息广播到它知道的 所有队列中。
 *  *                     系统中默认有些 exchange 类型
 */
public class Task04 {

    //声明交换机的名字
    private static final String EXCHANGE_NAME = "logs";

    public static void main(String[] args) throws IOException, TimeoutException {
        //获取信道
        Channel channel = RabbitMqUtils.getChannel();

        //获取控制台的用户输入
        Scanner scanner = new Scanner(System.in);
        System.out.println("请输入消息内容：");
        while (scanner.hasNext()){
            String message = scanner.next();
            //发送消息
            channel.basicPublish(EXCHANGE_NAME,"",null,message.getBytes());
            System.out.println("消息发送完毕");
        }

    }
}
